import fs from 'node:fs';
import path from 'node:path';

import { AsyncAPIDocumentV3 } from '../../src/models';
import { Parser } from '../../src/parser';
import { filterLastVersionDiagnostics } from '../utils';

describe('Adeo case study spec', function() {
  const parser = new Parser();
  const specPath = path.join(__dirname, '../mocks/adeo-case-study.yaml');
  const spec = fs.readFileSync(specPath, 'utf8');

  it('should parse the Adeo case study document without registering AvroSchemaParser', async function() {
    const { document, diagnostics } = await parser.parse(spec, { source: specPath });

    expect(document).toBeInstanceOf(AsyncAPIDocumentV3);
    expect(document).toBeDefined();
    expect(filterLastVersionDiagnostics(diagnostics).length === 0).toEqual(true);

    const channel = document!.allChannels().get('costingRequestChannel');
    const responseChannel = document!.allChannels().get('costingResponseChannel');
    const operation = document!.allOperations().get('receiveACostingRequest');

    expect(document!.allServers()).toHaveLength(3);
    expect(document!.allServers().all().map(server => server.id())).toEqual([
      'production',
      'staging',
      'dev',
    ]);

    expect(channel?.address()).toEqual('adeo-{env}-case-study-COSTING-REQUEST-{version}');
    expect(channel?.bindings().get('kafka')?.json()).toEqual({
      replicas: 3,
      partitions: 3,
      topicConfiguration: {
        'cleanup.policy': ['delete'],
        'retention.ms': 60000000,
      },
    });

    expect(responseChannel?.address()).toBeNull();
    expect(responseChannel?.bindings().get('kafka')?.json()?.['x-key.subject.name.strategy']?.type).toEqual('string');

    expect(operation?.summary()).toContain('[COSTING]');
    expect(operation?.bindings().get('kafka')?.json()?.groupId?.type).toEqual('string');

    const requestMessage = document!.allMessages().find(msg => msg.name() === 'CostingRequestV1');
    expect(requestMessage?.title()).toEqual('Costing Request V1');
    expect(requestMessage?.payload()?.schemaFormat()).toEqual('application/vnd.apache.avro;version=1.9.0');
  });
});